// 云函数入口文件
const cloud = require('wx-server-sdk')

cloud.init({env: 'test-3522f'})
const db = cloud.database()
const _ = db.command
// 云函数入口函数
exports.main = async (event, context) => {
   const wxContext = cloud.getWXContext();
   const queue_id = event.queue_id
   try{
      return await db.collection("userInfo").get().then(res=>{
         for (let i = 0; i < res.data[0].queuer.length; i++){
            if(res.data[0].queuer[i]._id == queue_id){
               await db.collection('userInfo')
                  .where({
                     _openid:wxContext.OPENID
                  })
                  .update({
                     data:{
                        [res.data[0].queuer[i].state]:"结束"
                     }
                  })
            }
         }
      }).then(res=>{
         return res
      })
   }catch(err){
      console.log(err)
      return err
   }
   // try{
   //    return await db.collection("userInfo").where({
   //       queuer:_.elemMatch({
   //          _id:"2b4144565e8"
   //       })
   //    }).update({

   //    })
   // }catch(err){
   //    console.log(err)
   //    return err
   // }

}